package com.jd.jobkeeper.server.transport;

import com.jd.jobkeeper.protocals.SetupRequest;
import com.jd.jobkeeper.transport.DefaultTransport;
import io.rsocket.RSocket;

public class ServerTransport extends DefaultTransport {

    private final SetupRequest setupRequest;

    public ServerTransport(SetupRequest setupRequest, RSocket sendingSocket) {
        super(setupRequest.getHost(),setupRequest.getPort());
        this.rSocket = sendingSocket;
        this.setupRequest = setupRequest;
    }

    public SetupRequest getSetupRequest() {
        return setupRequest;
    }
}
